package spring.module.disruptor.log;

import com.lmax.disruptor.EventHandler;

import lombok.extern.slf4j.Slf4j;

/**
 * 日志处理
 *  
 * @author Lucky Yang
 */
@Slf4j
public class LogEventHandler implements EventHandler<LogEvent> {

    /**
     * 
     * event ：待消费/处理的事件
     * sequence ：正在处理的事件在环形数组（RingBuffer）中的位置
     * endOfBatch : 表示这是否是来自环形数组（RingBuffer）中一个批次的最后一个事件（批量处理事件）
     */
    @Override
    public void onEvent(LogEvent event, long sequence, boolean endOfBatch) throws Exception {
        log.info("接收消息：{}", event.getMessage());
    }
    
}
